﻿<?php
/**
 *数据库访问对象设计
 */
interface sql{
	/**
	 * 执行查询
	 *
	 * @param string $sql 数据库sql命令
	 * @return mixed 命令执行结果资源集
	 */
	public static function query($sql);
	/**
	 * 取得查询操作
	 *
	 * @param string $sql 数据库sql命令
	 * @return bool/null/array
	 */
	public static function getAll($sql);	
	/**
     * 检索数据
     *
     * @param array $param 参数
     * @param object $obj_page 分类对象
     * @return array
     */
	public static function select($param,$obj_page='');
	/**
	 * 插入操作
	 *
	 * @param string $t_name 表名
	 * @param array $insert_array 待插入数据
	 * @return mixed
	 */
	public static function insert($t_name,$insert_array=array());
	/**
	 * 批量插入
	 *
	 * @param string $t_name 表名
	 * @param array $insert_array 待插入数据
	 * @return mixed
	 */
	public static function insertAll($t_name,$insert_array=array());
	/**
	 * 更新操作
	 *
	 * @param string $t_name 表名
	 * @param array $update_array 待更新数据
	 * @param string $where 执行条件
	 * @return bool
	 */
	public static function update($t_name,$update_array=array(),$where='');
	/**
	 * 删除
	 *
	 * @param string $t_name 表名
	 * @param string $where 执行条件
	 * @return bool
	 */
	public static function delete($t_name,$where='');
	/**
	 * 取取insert_id
	 *
	 * @return int
	 */
	public static function getLastId();
	/**
	 * 取得一行信息
	 *
	 * @param array $param array('table'=>'','field'=>'','value'=>'')
	 * @param string $fields
	 * @return array
	 */
	public static function getRow($param,$fields='*');
	/**
	 * 执行REPLACE操作
	 *
	 * @param string $t_name 表名
	 * @param array $replace_array 待更新的数据
	 * @return bool
	 */
	public static function replace($t_name,$replace_array=array());
	/**
	 * 返回单表查询记录数量
	 *
	 * @param string $t_name 表名
	 * @param $condition mixed 查询条件，可以为空，也可以为数组或字符串
	 * @return int
	 */
	public static function getCount($t_name,$condition=null);
	/**
	 * 执行SQL语句
	 *
	 * @param string $sql
	 * @return
	 */
	public static function execute($sql);
	/**
	 * 列出所有表
	 *
	 * @return array
	 */
	public static function showTables();
	/**
	 * 显示建表语句
	 *
	 * @param string $t_name
	 * @return string
	 */
	public static function showCreateTable($t_name);
	/**
	 * 显示表结构
	 *
	 * @param string $t_name
	 * @return array
	 */
	public static function showColumns($t_name);
	/**
	 * 取得服务器信息
	 *
	 * @return string
	 */
	public static function getServerInfo();
	/**
	 * 格式化字段
	 *
	 * @param string $key 字段名
	 * @return string
	 */
	public static function parseKey(&$key);
	/**
     * 格式化值
     *
     * @param mixed $value
     * @return mixed
     */
	public static function parseValue($value);
	/**
     * 开始一项新的事务
     */
	public static function beginTransaction();
	/**
     * 提交事务
     */
	public static function commit();
	/**
     * 回滚事务
     */
	public static function rollback();
}

abstract class Base_MySql implements sql{
	
}
class MySql extends Base_MySql{
	//创建数据库连接
	private static $link = null;
	//事务状态
	private static $iftransacte = true;
	
 	private function __construct(){
 		//检查该系统函数是否存在，如果不存在就不能使用该对象操作数据库
		if (!function_exists ("mysql_connect")){
			//弹出异常信息
			throw_exception('Db Error: mysql is not install');
		}
	}
	
	private static function connect(){
		//检查变量是否为对象类型
		if (is_object(self::$link)) return;
		$conf['dbhost'] = 'localhost';	//数据库主机名及IP
		$conf['dbport'] = '3306';		//数据库端口号
		$conf['dbname'] = 'pro';		//数据库名称
		$conf['dbuser'] = 'root';		//数据库用户名
		$conf['dbpwd'] = '123abc';	//数据库密码
		$conf['dbcharset'] = 'UTF-8';	//字符集编码
		//创建数据库服务器连接
		if (@self::$link = mysql_connect($conf['dbhost'].':'.$conf['dbport'], $conf['dbuser'], $conf['dbpwd'])){
			//选择数据库
			if (!@mysql_select_db($conf['dbname'],self::$link)){
				throw_exception("Db Error: ".mysql_error(self::$link));
			}
			switch (strtoupper($conf['dbcharset'])){
				case 'UTF-8':
					//字符集、字符序
					$query_string = "
		                 SET CHARACTER_SET_CLIENT = utf8,
		                 CHARACTER_SET_CONNECTION = utf8,
		                 CHARACTER_SET_DATABASE = utf8,
		                 CHARACTER_SET_RESULTS = utf8,
		                 CHARACTER_SET_SERVER = utf8,
		                 COLLATION_CONNECTION = utf8_general_ci,
		                 COLLATION_DATABASE = utf8_general_ci,
		                 COLLATION_SERVER = utf8_general_ci,
		                 sql_mode=''";
					break;
				case 'GBK':
					$query_string = "
		   			    SET CHARACTER_SET_CLIENT = gbk,
		                 CHARACTER_SET_CONNECTION = gbk,
		                 CHARACTER_SET_DATABASE = gbk,
		                 CHARACTER_SET_RESULTS = gbk,
		                 CHARACTER_SET_SERVER = gbk,
		                 COLLATION_CONNECTION = gbk_chinese_ci,
		                 COLLATION_DATABASE = gbk_chinese_ci,
		                 COLLATION_SERVER = gbk_chinese_ci,
		                 sql_mode=''";
					break;
				default:
					throw_exception("Db Error: charset is Invalid");
			}
			//执行字符集、字符序命令
			if (!mysql_query($query_string)){
				throw_exception("Db Error: ".mysql_error(self::$link));
			}
		}else {
			throw_exception("Db Error: database connect failed");
		}
	}
	/**
	 * 执行查询
	 *dd
	 * @param string $sql 数据库sql命令
	 * @return mixed 命令执行结果资源集
	 */
	public static function query($sql){
		self::connect();
		$query = mysql_query($sql,self::$link);
		if ($query === false){
			$error = "Db Error: ".mysql_error(self::$link);
			throw_exception($error.'<br/>'.$sql);
		}else {
			return $query;
		}
	}
	/**
	 * 取得查询操作
	 *
	 * @param string $sql 数据库sql命令
	 * @return bool/null/array
	 */
	public static function getAll($sql){
		self::connect();
		$result = self::query($sql);
		if ($result === false) return array();
		$array = array();
		while ($tmp=mysql_fetch_array($result,MYSQL_ASSOC)){//遍历数据集到数组中
			$array[] = $tmp;
		}
		return !empty($array) ? $array : null;
	}
	/**
     * 检索数据
     *
     * @param array $param 参数
     * @param object $obj_page 分类对象
     * @return array
     */
	public static function select($param,$obj_page=''){
		self::connect();
		static $_cache = array();
		if (empty($param)){
			throw_exception('Db Error: select param is empty!');
		}
		if (empty($param['field'])){
			$param['field'] = '*';
		}
		if (empty($param['count'])){
			$param['count'] = 'count(*)';
		}
		if (isset($param['index'])){
			$param['index'] = 'USE INDEX ('.$param['index'].')';
		}else{
			$param['index'] = '';
		}
		
		if (trim($param['where']) != ''){
			if (strtoupper(substr(trim($param['where']),0,5)) != 'WHERE'){
				if (strtoupper(substr(trim($param['where']),0,3)) == 'AND'){
					$param['where'] = substr(trim($param['where']),3);
				}
				$param['where'] = 'WHERE '.$param['where'];
			}
		}
		$param['where_group'] = '';
		if (!empty($param['group'])){
			$param['where_group'] .= ' group by '.$param['group'];
		}
		$param['where_order'] = '';
		if (!empty($param['order'])){
			$param['where_order'] .= ' order by '.$param['order'];
		}
		//判断是否是联表查询
		$tmp_table = explode(',',$param['table']);
		if (!empty($tmp_table) && count($tmp_table) > 1){
			if ((count($tmp_table)-1) != count($param['join_on'])){
				throw_exception('Db Error: join number is wrong!');
			}
			foreach($tmp_table as $key=>$val){
				$tmp_table[$key] = trim($val) ;
			}
			//拼join on 语句
			$tmp_sql = '';
			for ($i=1;$i<count($tmp_table);$i++){
				$tmp_sql .= $param['join_type'].' `'.$tmp_table[$i].'` as `'.$tmp_table[$i].'` ON '.$param['join_on'][$i-1].' ';
			}
			$sql = 'SELECT '.$param['field'].' FROM `'.$tmp_table[0].'` as `'.$tmp_table[0].'` '.$tmp_sql.' '.$param['where'].$param['where_group'].$param['where_order'];

			//如果有分页，计算信息总数
			$count_sql = 'SELECT '.$param['count'].' as count FROM `'.$tmp_table[0].'` as `'.$tmp_table[0].'` '.$tmp_sql.' '.$param['where'].$param['where_group'];
		}else {
			$sql = 'SELECT '.$param['field'].' FROM `'.$param['table'].'` as `'.$param['table'].'` '.$param['index'].' '.$param['where'].$param['where_group'].$param['where_order'];
			$count_sql = 'SELECT '.$param['count'].' as count FROM `'.$param['table'].'` as `'.$param['table'].'` '.$param['index'].' '.$param['where'];
		}
		//limit ，如果有分页对象的话，那么优先分页对象
		if ($obj_page instanceof Page ){
			$count_query = self::query($count_sql);
			$count_fetch = mysql_fetch_array($count_query,MYSQL_ASSOC);
			$obj_page->setTotalNum($count_fetch['count']);
			$param['limit'] = $obj_page->getLimitStart().",".$obj_page->getEachNum();
		}
		if ($param['limit'] != ''){
			$sql .= ' limit '.$param['limit'];
		}
		if ($param['cache'] !== false){
			//$key =  is_string($param['cache_key'])?$param['cache_key']:md5($sql);
			$key =  md5($sql);
			if (isset($_cache[$key])) return $_cache[$key];
		}
		$result = self::query($sql);
		if ($result === false) $result = array();
		while ($tmp=mysql_fetch_array($result,MYSQL_ASSOC)){
			$array[] = $tmp;
		}
		if ($param['cache'] !== false && !isset($_cache[$key])){
			$_cache[$key] = $array;
		}
		return $array;
	}
	/**
	 * 插入操作
	 *
	 * @param string $t_name 表名
	 * @param array $insert_array 待插入数据
	 * @return mixed
	 */
	public static function insert($t_name,$insert_array=array()){
	
	}
	/**
	 * 批量插入
	 *
	 * @param string $t_name 表名
	 * @param array $insert_array 待插入数据
	 * @return mixed
	 */
	public static function insertAll($t_name,$insert_array=array()){
	
	}
	/**
	 * 更新操作
	 *
	 * @param string $t_name 表名
	 * @param array $update_array 待更新数据
	 * @param string $where 执行条件
	 * @return bool
	 */
	public static function update($t_name,$update_array=array(),$where=''){
	
	}
	/**
	 * 删除
	 *
	 * @param string $t_name 表名
	 * @param string $where 执行条件
	 * @return bool
	 */
	public static function delete($t_name,$where=''){
	
	}
	/**
	 * 取取insert_id
	 *
	 * @return int
	 */
	public static function getLastId(){
	
	}
	/**
	 * 取得一行信息
	 *
	 * @param array $param array('table'=>'','field'=>'','value'=>'')
	 * @param string $fields
	 * @return array
	 */
	public static function getRow($param,$fields='*'){
	
	}
	/**
	 * 执行REPLACE操作
	 *
	 * @param string $t_name 表名
	 * @param array $replace_array 待更新的数据
	 * @return bool
	 */
	public static function replace($t_name,$replace_array=array()){
	
	}
	/**
	 * 返回单表查询记录数量
	 *
	 * @param string $t_name 表名
	 * @param $condition mixed 查询条件，可以为空，也可以为数组或字符串
	 * @return int
	 */
	public static function getCount($t_name,$condition=null){
	
	}
	/**
	 * 执行SQL语句
	 *
	 * @param string $sql
	 * @return
	 */
	public static function execute($sql){
	
	}
	/**
	 * 列出所有表
	 *
	 * @return array
	 */
	public static function showTables(){
	
	}
	/**
	 * 显示建表语句
	 *
	 * @param string $t_name
	 * @return string
	 */
	public static function showCreateTable($t_name){
	
	}
	/**
	 * 显示表结构
	 *
	 * @param string $t_name
	 * @return array
	 */
	public static function showColumns($t_name){
	
	}
	/**
	 * 取得服务器信息
	 *
	 * @return string
	 */
	public static function getServerInfo(){
	
	}
	/**
	 * 格式化字段
	 *
	 * @param string $key 字段名
	 * @return string
	 */
	public static function parseKey(&$key){
	
	}
	/**
     * 格式化值
     *
     * @param mixed $value
     * @return mixed
     */
	public static function parseValue($value){
	
	}
	/**
     * 开始一项新的事务
     */
	public static function beginTransaction(){
	
	}
	/**
     * 提交事务
     */
	public static function commit(){
	
	}
	/**
     * 回滚事务
     */
	public static function rollback(){
	
	}
}
?>
